/******************************************************************************
 * SAGE - Scalable Adaptive Graphics Environment
 *
 * Module: messageInterface.h
 * Author : Byungil Jeong
 *
 * Copyright (C) 2004 Electronic Visualization Laboratory,
 * University of Illinois at Chicago
 *
 * This library is free software; you can redistribute it and/or modify it
 * under the terms of the GNU Lesser General Public License as published by
 * the Free Software Foundation; either Version 2.1 of the License, or
 * (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
 * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public
 * License for more details.
 *
 * You should have received a copy of the GNU Lesser Public License along
 * with this library; if not, write to the Free Software Foundation, Inc.,
 * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
 *
 * Direct questions, comments etc about SAGE to bijeong@evl.uic.edu or 
 * http://www.evl.uic.edu/cavern/forum/
 *
 *****************************************************************************/

#ifndef _MSGINTF_H
#define _MSGINTF_H

#include "sage.h"
#include <QUANTA/QUANTA.hxx> 
#include <QUANTA/QUANTAnet_tcp_c.hxx>

class msgInfConfig {
public:
	bool	master;
	char	serverIP[SAGE_IP_LEN];
	int	serverPort;

	msgInfConfig() : serverPort(0), master(true) { serverIP[0] = '\0'; }
};

class messageInterface {
private:
	QUANTAnet_tcpServer_c *msgServer;
	std::vector<QUANTAnet_tcpClient_c *> msgClientList;
	msgInfConfig config;
	int readIdx;
	
public:
	messageInterface();
	~messageInterface();
	int init(msgInfConfig &conf);
	int connect(char *ip, int port);
	int checkClients();
	int readMsg(sageMessage &msg);
	// return 1 : data read, return 0 : no data, return -1 : connection terminated
	
	int distributeMessage(sageMessage &msg, int *clientList, int clientNum);
	int distributeMessage(int code, int instID, int *clientList, int clientNum);
	int msgToClient(sageMessage &msg);
	int msgToClient(int cId, int instID, int code);
	int msgToClient(int cId, int instID, int code, int data);
	int msgToClient(int cId, int instID, int code, char *data);
	int msgToServer(int instID, int code);
	int msgToServer(int instID, int code, int data);
	int msgToServer(int instID, int code, char *data);
	int getNumClients() { return msgClientList.size(); }
};

#endif
